package org.future.task.redis.commit;

import org.future.task.core.handler.Commit;

import java.util.List;

public abstract class RedisCommit<Data> implements Commit<Data> {

    public abstract void submit(String queueName, List<Data> dataList) throws InterruptedException;

    public abstract void submit(String queueName, Data data) throws InterruptedException;

    public abstract List<Data> getBatch(String queueName, int size) throws InterruptedException;


}
